package com.ruoyi.project.flink.latest

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

object StreamWordCount {

  def main(args: Array[String]): Unit = {

//    //创建流处理的执行环境
//    val env = StreamExecutionEnvironment.getExecutionEnvironment
//
//    //接收一个socket文本流
//    val inputDataStream = env.socketTextStream("127.0.0.1",7777)
//
//    //进行转换处理统计
//    val resultDataStreams = inputDataStream
//      .map((_, 1))  //每次给key设置数量
//      .keyBy(0) //按照第一个key来做聚合
//      .sum(1) //做统计
//
//    resultDataStreams.print()
//    //最终执行的操作
//    env.execute("stream world count")

  }
}
